package com.yuanchu.messages.service;

import com.yuanchu.messages.entity.MqMessage;
import com.baomidou.mybatisplus.extension.service.IService;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
* @author adan
* @description 针对表【mq_message】的数据库操作Service
* @createDate 2024-02-22 18:52:49
*/
public interface MqMessageService extends IService<MqMessage> {

    List<MqMessage> getMessageList(int shardIndex, int shardTotal, String messageType, int count);

    MqMessage addMessage(String messageType, String businessKey1, String businessKey2, String businessKey3);

    @Transactional
    int completed(long id);

    int completedStageOne(long id);

    int completedStageTwo(long id);

    int completedStageThree(long id);

    int completedStageFour(long id);

    int getStageOne(long id);

    int getStageTwo(long id);

    int getStageThree(long id);

    int getStageFour(long id);
}
